package net.neptech.topics;

import org.apache.kafka.clients.admin.NewTopic;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class AppointmentDTLTopics {
    @Value("delayed-message-topic-appointment")
    private   String Appointment_MESSAGE_TOPIC ;

    /**
     * 延迟队列
     * @return
     */
    @Bean
    public NewTopic delayedMessageTopic() {
        return new NewTopic(Appointment_MESSAGE_TOPIC, 3, (short) 1);
    }

}
